b737a232d34b1ccdb399fdc2147106f7eeff6615,src/main/java/com/steelbridgelabs/oss/neo4j/structure/Neo4JSession.java,Neo4JSession,loadEdge,#Record#,521

Before Change


                Object firstNodeId = firstNode.get(vertexIdFieldName).asObject();
                Object secondNodeId = secondNode.get(vertexIdFieldName).asObject();
                // check edge has been deleted (one of the vertices was deleted)
                if (deletedVertices.contains(firstNodeId) || deletedVertices.contains(secondNodeId) || (!partition.isEmpty() && (!StreamSupport.stream(firstNode.labels().spliterator(), false).anyMatch(partition::contains) || !StreamSupport.stream(secondNode.labels().spliterator(), false).anyMatch(partition::contains))))
                    return null;
                // check we have first vertex in memory
                Neo4JVertex firstVertex = vertices.get(firstNodeId);

After Change


                Object firstNodeId = firstNode.get(vertexIdFieldName).asObject();
                Object secondNodeId = secondNode.get(vertexIdFieldName).asObject();
                // check edge has been deleted (one of the vertices was deleted) or the vertices are not in the read partition
                if (deletedVertices.contains(firstNodeId) || deletedVertices.contains(secondNodeId) || !partition.containsVertex(StreamSupport.stream(firstNode.labels().spliterator(), false).collect(Collectors.toSet())) || !partition.containsVertex(StreamSupport.stream(secondNode.labels().spliterator(), false).collect(Collectors.toSet())))
                    return null;
                // check we have first vertex in memory
                Neo4JVertex firstVertex = vertices.get(firstNodeId);